//package com.xsj.controller;
//
//import com.xsj.client.ChatClient;
//import com.xsj.vo.MyMessage;
//
////import org.apache.rocketmq.client.impl.consumer.MessageRequest;
//import org.checkerframework.checker.units.qual.A;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.lang.reflect.Constructor;
//
///**
// * @BelongsProject: MerchantController.java
// * @BelongsPackage: com.xsj.controller
// * @Author: tutu
// * @CreateTime: 2025-06-27 15:53
// * @Description: TODO
// * @Version: 1.0
// */
//@RestController
//@RequestMapping("/message")
//public class MessageController {
//    @Autowired
//    private ChatClient client;
//
//    @PostMapping("/send")
//    public void send(@RequestBody MyMessage message ){
//        client.sendMessageToMerchant(message.getMerchantId(),message.getContent());
//        try {
//            Class<?> clazz = Class.forName("org.apache.rocketmq.client.impl.consumer.MessageRequest");
//            Constructor<?> constructor = clazz.getDeclaredConstructors()[0];
//            constructor.setAccessible(true);
//            Object messageRequest = constructor.newInstance(/* 构造参数 */);
//            System.out.println("强制创建实例: " + messageRequest);
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//
//}
